//package cn.gemframe.kafka;
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.messaging.support.MessageBuilder;
//
//@EnableBinding(AcceptLogsWrite.class)
//public class AcceptLogsWriteService {
//
//	@Autowired
//	private AcceptLogsWrite acceptLogsWrite;
//
//	public void sendMessage(String message) {
//		try {
//			acceptLogsWrite.output1().send(MessageBuilder.withPayload(message).build());
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//	}
//}
